'use strict';
var vk; // 全局vk实例
// 涉及的表名
const dbName = require("../../../dao/config.js");

var db = uniCloud.database(); // 全局数据库引用
var _ = db.command; // 数据库操作符
var $ = _.aggregate; // 聚合查询操作符
/**
 * 权限注意：访问以下链接查看
 * 文档地址：https://vkdoc.fsq.pub/client/uniCloud/cloudfunctions/cloudObject.html#内置权限
 */
var cloudObject = {
	isCloudObject: true, // 标记为云对象模式
	/**
	 * 请求前处理，主要用于调用方法之前进行预处理，一般用于拦截器、统一的身份验证、参数校验、定义全局对象等。
	 * 文档地址：https://vkdoc.fsq.pub/client/uniCloud/cloudfunctions/cloudObject.html#before-预处理
	 */
	_before: async function() {
		vk = this.vk; // 将vk定义为全局对象
		// let { customUtil, uniID, config, pubFun } = this.getUtil(); // 获取工具包
	},
	/**
	 * 请求后处理，主要用于处理本次调用方法的返回结果或者抛出的错误
	 * 文档地址：https://vkdoc.fsq.pub/client/uniCloud/cloudfunctions/cloudObject.html#after-后处理
	 */
	_after: async function(options) {
		let { err, res } = options;
		if (err) {
			return; // 如果方法抛出错误，直接return;不处理
		}
		return res;
	},
	/**
	 * 获取列表
	 * @url admin/business/sys.goodsComment.getList 前端调用的url参数地址
	 */
	getList: async function(data) {
		let res = { code: 0, msg: '' };
		// 业务逻辑开始-----------------------------------------------------------
		res = await vk.daoCenter.goodsCommentDao.getTableData({
			data
		});
		// 业务逻辑结束-----------------------------------------------------------
		return res;
	},
	/**
	 * 修改
	 * @url admin/business/sys.goodsComment.update 前端调用的url参数地址
	 */
	update: async function(data) {
		let res = { code: 0, msg: '' };
		// 业务逻辑开始-----------------------------------------------------------
		let {
			_id,
			ids,
			status,
		} = data;
		// 修改并返回修改后的数据
		if (vk.pubfn.isNullAll(_id, ids)) return { code: -1, msg: "参数错误" };
		if (vk.pubfn.isNotNull(_id)) {
			ids = [_id];
		}
		let whereJson = {
			_id: _.in(ids)
		};
		res.num = await vk.daoCenter.goodsCommentDao.update({
			whereJson,
			dataJson: {
				status
			}
		});
		if (res.num > 0) {
			let goodsCommentList = await vk.daoCenter.goodsCommentDao.select({
				pageIndex: 1,
				pageSize: ids.length,
				getMain: true,
				whereJson
			});
			let goods_ids = goodsCommentList.map((item, index) => {
				return item.goods_id;
			});
			// 去重复
			goods_ids = [...new Set(goods_ids)];
			for (let i = 0; i < goods_ids.length; i++) {
				let goods_id = goods_ids[i];
				// 更新商品累计评价数量
				await vk.daoCenter.goodsDao.updateCommentCount(goods_id);
			}
		}
		res.msg = "修改成功";
		res.status = status;
		// 业务逻辑结束-----------------------------------------------------------
		return res;
	},
	/**
	 * 删除
	 * @url admin/business/sys.goodsComment.delete 前端调用的url参数地址
	 */
	delete: async function(data) {
		let res = { code: 0, msg: '' };
		// 业务逻辑开始-----------------------------------------------------------
		let {
			_id
		} = data;
		let info = await vk.daoCenter.goodsCommentDao.findById(_id);
		// 删除评价
		await vk.daoCenter.goodsCommentDao.deleteById(_id);
		// 更新商品累计评价数量
		await vk.daoCenter.goodsDao.updateCommentCount(info.goods_id);
		// 业务逻辑结束-----------------------------------------------------------
		return res;
	},
	/**
	 * 模板函数
	 * @url admin/business/sys.goodsComment.test 前端调用的url参数地址
	 */
	test: async function(data) {
		let res = { code: 0, msg: '' };
		// 业务逻辑开始-----------------------------------------------------------


		// 业务逻辑结束-----------------------------------------------------------
		return res;
	},
};

module.exports = cloudObject;
